Многопоточное программирование в Java - Тимур Машнин

которых издатели создают элементы данных, которые потребляются одним или несколькими подписчиками.

Это интерфейс Publisher — производитель элементов данных, получаемых подписчиками.

Интерфейс Subscriber — приемник элементов данных.

Интерфейс Subscription — связь между издателем и подписчиком.

И интерфейс Processor — комбинация Publisher и Subscriber для преобразования данных.

Издатель публикует поток данных для зарегистрированных подписчиков и реализует интерфейс Flow. Publisher.

Этот интерфейс объявляет единственный метод, который вызывается для регистрации подписчика у издателя.

Вызов этого метода регистрирует подписчика у издателя.

Однако, если подписчик уже зарегистрирован или регистрация терпит неудачу, этот метод вызывает метод onError подписчика с объектом IllegalStateException.

При удачной подписке вызывается метод onSubscribe подписчика с новым объектом Flow.Subscription.

Подписчик подписывается на издателя для получения элементов данных и реализует интерфейс Flow.Subscriber.

Этот интерфейс объявляет метод onSubscribe и три дополнительных метода.

Метод onSubscribe вызывается для подтверждения регистрации.

Он получает в качестве аргумента подписку, методы которой позволяют запрашивать новые элементы данных у издателя или запрашивать, чтобы издатель больше не отправлял элементы данных.

Метод onComplete вызывается, когда издатель закрывает подписку.

Метод onError вызывается при возникновении ошибки в процессе подписки.

Метод onNext вызывается, когда издатель публикует элемент данных.

Подписка обеспечивает связь между издателем и подписчиком, позволяя подписчикам получать данные только по запросу и позволяя отменить подписку в любое время.

Подписка реализует интерфейс Flow.Subscription, который объявляет два метода.

Метод request добавляет n элементов данных к текущему невыполненному требованию для этой подписки.

Если n меньше или равно 0, метод onError подписчика вызывается с аргументом IllegalArgumentException.

В противном случае подписчик получает до n дополнительных вызовов метода onNext.

Передача в качестве аргумента значения Long.MAX_VALUE указывает неограниченное количество вызовов.

Метод cancel отменяет подписку. Но дополнительные элементы данных могут быть получены после вызова метода cancel.

Наконец, процессор представляет собой функцию преобразования данных, которая работает в потоке.

Один или несколько процессоров могут быть размещены между издателем и подписчиком для преобразования одного потока данных в другой.

Класс SubmissionPublisher реализует интерфейс Flow. Publisher, асинхронно выдавая ненулевые элементы данных текущим подписчикам до тех пор, пока подписка не будет закрыта.

Каждый текущий подписчик получает вновь представленные элементы данных в том же порядке, что и их публикация, если они не будут утеряны или не будет выброшено исключение.

SubmissionPublisher предоставляет три конструктора для инициализации издателя.

Простейший конструктор без аргументов создает издателя, который использует метод ForkJoinPool.commonPool, чтобы обеспечить асинхронность, необходимую для доставки элементов данных подписчикам.

Здесь мы создаем объект SubmissionPublisher издателя и регистрируем для него подписчика MySubscriber.

Затем издатель в строковом потоке публикует элементы потока.

После чего издатель закрывает подписку.

Подписчик MySubscriber реализует интерфейс Subscriber.

В методе подписки onSubscribe он запрашивает элемент данных у издателя.

Когда издатель публикует элемент данных, вызывается метод onNext подписчика, в котором он запрашивает еще элемент данных у издателя.